package com.learn.queue.safety.blocking;

import com.learn.constant.MathConstant;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.PriorityBlockingQueue;

/**
 * 测试PriorityBlockingQueueTest
 */
public class PriorityBlockingQueueTest {

    public static void main(String[] args){

        BlockingQueue<String> queue = new PriorityBlockingQueue<>(MathConstant.INT_TEN);

        ExecutorService service = Executors.newCachedThreadPool();

        service.shutdown();

    }
}
